const sql = require('mssql');

// 数据库配置，新厂我的主数据库
const config = {
  server: '10.1.21.42',
  port: 1433,
  user: 'sa',
  password: 'Dg@123456',
  database: 'XL.WeightBridge.DAGANG',
  options: {
    encrypt: false, // 如果使用加密连接，设置为 true
    trustServerCertificate: true // 信任服务器证书
  },
  pool: {
    max: 10,
    min: 0,
    idleTimeoutMillis: 30000
  }
};

// 执行数据库操作
async function sqlConnect(sqlstr, params) {
  let connection;
  try {
    connection = await sql.connect(config);
    return await connection.query(sqlstr, params);
  } catch (err) {
    console.error('数据库操作失败:', err);
    throw err; // 抛出错误以便调用方处理
  } finally {
    if (connection) {
      await connection.close();
      // console.log('数据库连接已关闭');
    }
  }
}

module.exports=sqlConnect;
